982501a5ed2c5b0eb55a24a87e98bd871c59068a,src/test/java/net/jodah/failsafe/ListenerConfigTest.java,ListenerConfigTest,bindListeners,#SyncFailsafe#,114

Before Change



    failsafe.onAbort(e -> abort.incrementAndGet());
    failsafe.onAbort((r, e) -> abortResult.incrementAndGet());
    failsafe.onAbort((r, e, c) -> ctxAbort.incrementAndGet());
    failsafe.onAbortAsync(e -> {
      asyncAbort.incrementAndGet();
      waiter.resume();
    } , executor);
    failsafe.onAbortAsync((r, e) -> {
      asyncAbortResult.incrementAndGet();
      waiter.resume();
    } , executor);
    failsafe.onAbortAsync((r, e, c) -> {
      asyncCtxAbort.incrementAndGet();
      waiter.resume();
    } , executor);

    failsafe.onFailure(e -> failure.incrementAndGet());
    failsafe.onFailure((r, f) -> failureResult.incrementAndGet());
    failsafe.onFailure((r, f, s) -> ctxFailure.incrementAndGet());
    failsafe.onFailureAsync(e -> asyncFailure.incrementAndGet(), executor);
    failsafe.onFailureAsync((r, f) -> asyncFailureResult.incrementAndGet(), executor);
    failsafe.onFailureAsync((r, f, s) -> asyncCtxFailure.incrementAndGet(), executor);

After Change


  <T> SyncFailsafe<T> registerListeners(SyncFailsafe<T> failsafe) {
    failsafe.onAbort(e -> abort.sync(1));
    failsafe.onAbort((r, e) -> abort.sync(2));
    failsafe.onAbort((r, e, c) -> abort.sync(3));
    failsafe.onAbortAsync(e -> abort.async(4), executor);
    failsafe.onAbortAsync((r, e) -> abort.async(5), executor);
    failsafe.onAbortAsync((r, e, c) -> abort.async(6), executor);
    abort.asyncListeners = 3;

    failsafe.onComplete((r, f) -> complete.sync(1));
    failsafe.onComplete((r, f, s) -> complete.sync(2));
    failsafe.onCompleteAsync((r, f) -> complete.async(3), executor);
    failsafe.onCompleteAsync((r, f, c) -> complete.async(4), executor);
    complete.asyncListeners = 2;

    failsafe.onFailedAttempt(e -> failedAttempt.sync(1));
    failsafe.onFailedAttempt((r, f) -> failedAttempt.sync(2));
    failsafe.onFailedAttempt((r, f, c) -> failedAttempt.sync(3, c));
    failsafe.onFailedAttemptAsync(e -> failedAttempt.async(4), executor);
    failsafe.onFailedAttemptAsync((r, f) -> failedAttempt.async(5), executor);
    failsafe.onFailedAttemptAsync((r, f, c) -> failedAttempt.async(6, c), executor);
    failedAttempt.asyncListeners = 3;

    failsafe.onFailure(e -> failure.sync(1));
    failsafe.onFailure((r, f) -> failure.sync(2));
    failsafe.onFailure((r, f, s) -> failure.sync(3));
    failsafe.onFailureAsync(e -> failure.async(4), executor);
    failsafe.onFailureAsync((r, f) -> failure.async(5), executor);
    failsafe.onFailureAsync((r, f, s) -> failure.async(6), executor);
    failure.asyncListeners = 3;